// 队列任务
package queue

import (
	"gitee.com/xgotool/backend-framework-template/app/queue/hook"
	"gitee.com/xgotool/backend-framework-template/app/queue/log"
	"gitee.com/xiaoyutab/xgotool/individual/xqueue"
)

// 初始化队列任务
func Init() {
	xqueue.AddMap(map[string]func(param []byte) error{
		// hook钩子部分
		"hook.address.create": hook.AddressCreate, // 地址创建钩子
		"hook.address.update": hook.AddressUpdate, // 地址修改钩子
		"hook.address.delete": hook.AddressDelete, // 地址删除钩子
		"hook.user.create":    hook.UserCreate,    // 用户创建钩子
		"hook.progress.clean": hook.ProgressClean, // 清理进度条的钩子

		// log日志部分
		"log.user": log.User, // 用户相关日志
		"log.p7z":  log.P7z,  // 访问日志的按天压缩配置
	})
}

// Listen 监听队列
func Listen() {
	Init()
	go xqueue.Listen()
}
